package com.zz.demo.core;

import com.zz.demo.entity.vo.ScanConfigVO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.File;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;

/**
 * 生产者
 */
public class ScanProducer extends Thread {
    private static final Logger logger = LoggerFactory.getLogger("ScanProducer");
    /**
     * 文件扫描配置类
     */
    ScanConfigVO scanConfigVO;
    /**
     * 正在发送的文件的阻塞队列
     */
    private BlockingQueue<String> sendingFiles;
    /**
     * 传输队列
     */
    private ConcurrentLinkedQueue<File> queue;
    /**
     * 线程锁
     */
    private Lock lock;
    /**
     * 通知释放锁
     */
    private Condition condition;
    private Integer sleepTime = 3;
    private Boolean isRunning;




}
